--[[
   编码: JX-60-12
   名称: 自动配盘
   作者：
   日期: 2025-1-29

   函数： main
   功能:
        -- 根据出库波次明细计算出配盘及配盘明细，再把出库货品批分到各出库单绑定的拣料箱

   备注：
        -- 该程序起源巨星二期料箱库，适合多料格料箱的出库分拣操作
        
   更改记录:
        V2.0 合并取消 combine_cntr_detail
--]]
wms_out = require( "wms_outbound" )
wms_station = require( "wms_station" )

local function get_d_cntr_detail_by_bs_no( d_cntr_detail_list, bs_no )
    local sub_d_cntr_detail_list = {}
    local n

    for n = 1, #d_cntr_detail_list do
        if ( d_cntr_detail_list[n].bs_no == bs_no ) then
            table.insert( sub_d_cntr_detail_list, d_cntr_detail_list[n])
        end
    end
    return sub_d_cntr_detail_list
end

-- 根据体积进行排序，体积大的放前面
local function dc_detail_sort_by_volume( t1, t2 )
    return t1.volume*t1.qty > t2.volume*t2.qty 
end

local function picking_box_sort_by_volume( t1, t2 )
    return t1.box_volume> t2.box_volume 
end

-- d_cntr_detail_list ( 某个出库单相关的配盘明细 ) pick_box_code 拣料箱编码
-- new_d_cntr_detail_list 批分结果
local function split_by_picking_box( strLuaDEID, d_cntr_detail_list, picking_box_code, new_d_cntr_detail_list )
    local nRet, strRetInfo
    local seg = lua.split( picking_box_code, ";" )   
    local n, m

    -- 初始化拣料箱
    local picking_box_list = {}
    local box_volume = wms_base.Get_nConst( strLuaDEID, "拣料箱体积")
    local pick_box_num = #seg
    for n = 1, pick_box_num do  
        local picking_box = {
            picking_box_code = seg[n],
            box_volume = box_volume,
        }  
        table.insert( picking_box_list, picking_box )
    end

    -- 把体积大的放前面
    table.sort( d_cntr_detail_list, dc_detail_sort_by_volume )

    -- 批分到不同的拣料箱
    local find, volume, qty, need_split_qty

    for n = 1, #d_cntr_detail_list do
        find = false
        volume = d_cntr_detail_list[n].qty*d_cntr_detail_list[n].volume
        for m = 1, pick_box_num do
            if ( volume <= picking_box_list[m].box_volume ) then
                d_cntr_detail_list[n].pick_box_code = picking_box_list[m].picking_box_code
                picking_box_list[m].box_volume = picking_box_list[m].box_volume - volume
                find = true
                break
            end
        end
        if ( find ) then
            table.insert( new_d_cntr_detail_list, d_cntr_detail_list[n] )
        else
            -- 需要批分，把一条【配盘明细】根据拣料箱
            need_split_qty = d_cntr_detail_list[n].qty       -- 需要批分的数量

            for m = 1, pick_box_num do
                if ( picking_box_list[m].box_volume > 0 ) then
                    qty = math.floor( picking_box_list[m].box_volume/ d_cntr_detail_list[n].volume )
                    if ( need_split_qty < qty ) then
                        qty = need_split_qty
                    end
                    need_split_qty = need_split_qty - qty

                    local d_cntr_detail = {
                        item_code = d_cntr_detail_list[n].item_code,
                        item_name = d_cntr_detail_list[n].item_name,
                        cntr_code = d_cntr_detail_list[n].cntr_code,
                        batch_no = d_cntr_detail_list[n].batch_no,
                        cell_no = d_cntr_detail_list[n].cell_no,
                        station = d_cntr_detail_list[n].station,
    
                        serial_no = d_cntr_detail_list[n].serial_no,
                        item_spec = d_cntr_detail_list[n].item_spec,
                        end_user = d_cntr_detail_list[n].end_user,
                        owner = d_cntr_detail_list[n].owner,        
                        uom = d_cntr_detail_list[n].uom,     
                        volume = d_cntr_detail_list[n].volume,  
                        weight = d_cntr_detail_list[n].weight,                          
                        wh_code = d_cntr_detail_list[n].wh_code,                 
                        area_code = d_cntr_detail_list[n].area_code,                 
                        loc_code = d_cntr_detail_list[n].loc_code,                 
    
                        cg_detail_id = d_cntr_detail_list[n].cg_detail_id,
                        bs_type = d_cntr_detail_list[n].bs_type,
                        bs_no = d_cntr_detail_list[n].bs_no,
                        bs_row_no = d_cntr_detail_list[n].bs_row_no,
                        wave_no = d_cntr_detail_list[n].wave_no,
                        wave_cls_id = d_cntr_detail_list[n].wave_cls_id,

                        pick_box_code = picking_box_list[m].picking_box_code,
                        qty = qty
                    }
                    picking_box_list[m].box_volume = picking_box_list[m].box_volume - qty*d_cntr_detail_list[n].volume
                    table.insert( new_d_cntr_detail_list, d_cntr_detail )
                end
                if ( need_split_qty == 0 ) then
                    break
                end
            end

            -- 如果还有 need_split_qty 说明无法分配拣货箱，这是有问题的需要报警
            if ( need_split_qty > 0 ) then
                return 1, "货品'"..d_cntr_detail_list[n].item_code.."'因为体积的原因无法分配拣料箱!"
            end
        end

        -- 把拣料箱可用容积最大的放前面
        table.sort( picking_box_list, picking_box_sort_by_volume )
    end
    return 0
end


-- 把配盘明细中相同料格的货品数量进行合并
-- Distribution_CNTR_Detail 合并，在出库的时候一个料格可能会有多条CG_Detail
local function combine_cntr_detail( d_cntr_detail_list )
    local n
    local combine_result = {}

    for n = 1, #d_cntr_detail_list do
        find = false
        for m = 1, #combine_result do
            if ( d_cntr_detail_list[n].cntr_code == combine_result[m].cntr_code and d_cntr_detail_list[n].cell_no == combine_result[m].cell_no ) then
                if ( d_cntr_detail_list[n].item_code ~= combine_result[m].item_code ) then
                    return 1, "合并配盘明细发生错误, 相同的料格存在不同编码的货品!"
                end
                find = true
                combine_result[m].qty = combine_result[m].qty + d_cntr_detail_list[n].qty
                -- MDF BY HAN 20250314
                combine_result[m].cg_detail_id = ""     -- 多条合并后CG_Detail要设置为空
            end
        end

        if ( find == false ) then
            table.insert( combine_result, d_cntr_detail_list[n] )
        end
    end

    return 0, combine_result
end

local function cg_detail_add_alloc_qty( strLuaDEID, d_cntr_detail_list )
    local m, nRet, strRetInfo

    for m = 1, #d_cntr_detail_list do
        -- CG_Detail 加分配量
        strCondition = "S_ID = '"..d_cntr_detail_list[m].cg_detail_id.."'"
        nRet, strRetInfo = mobox.incDataObjAccQty ( strLuaDEID, "CG_Detail", strCondition, "F_QTY", "F_ALLOC_QTY", lua.Get_NumAttrValue( d_cntr_detail_list[m].qty ) )
        if ( nRet ~= 0 or strRetInfo ~= '') then 
            return 1, '在增加【容器货品明细】中的分配量时失败!'..strRetInfo 
        end  
    end
    return 0
end

function main( strLuaDEID )
    local nRet, strRetInfo

    -- 获取出库波次对象属性
    nRet, strRetInfo = mobox.getCurEditDataObjAttr( strLuaDEID, "S_WAVE_NO", "N_B_STATE","S_WH_CODE","S_AREA_CODE","S_STATION_NO" )
    local input_value = json.decode( strRetInfo ) 
    local wave_no = lua.Get_StrAttrValue( input_value[1].value )
    local b_state = lua.Get_NumAttrValue( input_value[2].value )  
    local wh_code = lua.Get_StrAttrValue( input_value[3].value )
    local area_code = lua.Get_StrAttrValue( input_value[4].value ) 
    local station = lua.Get_StrAttrValue( input_value[5].value )  
    local err_msg = ''
    local n, strCondition, m
    local item_list = {}
    local d_cntr_list = {}              -- 配盘/Distribution_CNTR
    local d_cntr_detail_list = {}       -- 配盘明细/Distribution_CNTR_Detail   
    local oo_no_set = {} 
    local loc_code
    nRet, loc_code = wms_station.Get_Station_Loc( strLuaDEID, station )
    if ( nRet ~= 0 ) then
        lua.Stop( strLuaDEID, loc_code )
        return
    end 

    local detail_attrs, ow_compose
    local outbound_detail_list
    local data_objs    
    local pickbox_volume = wms_base.Get_nConst( strLuaDEID, "拣料箱体积")
    local oo_obj_attrs
    local pick_box_num
    local pick_box_code
    local new_d_cntr_detail_list = {}        -- 加了拣料箱编码后的 【配盘明细】
    local paramter = {}

    local exit_loc
    nRet, exit_loc = wms_wh.GetLocInfo( loc_code )
    if ( nRet ~= 0 ) then 
        err_msg = '获取站台货位信息失败! '..loc_code 
        goto set_state_ret
    end  

    if ( wave_no == '' ) then
        err_msg = '出库波次编码不能为空!' 
        goto set_state_ret
    end  
    if ( wh_code == '' ) then
        err_msg = '出库波次中仓库编码不能为空!' 
        goto set_state_ret
    end  

    -- 获取 出库波次 的出库单组成，生成一个 oo_no_set 对象,["OW01","OW02",...]
    strCondition = "S_WAVE_NO = '"..wave_no.."'"
    nRet, data_objs = m3.QueryDataObject(strLuaDEID, "OW_Compose", strCondition, "S_OO_NO" )
    if (nRet ~= 0) then return 2, "QueryDataObject失败!"..data_objs end
    if ( data_objs == '' ) then 
        -- 设置错误信息
        err_msg = "波次号'"..wave_no.."'的出库波次没有组成对象!"
        goto set_state_ret
    end
    for n = 1, #data_objs do
        ow_compose = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
        table.insert( oo_no_set, ow_compose.S_OO_NO )
    end

    -- 获取 出库波次 货品明细, 生成 item_list 需要出库的货品清单
    strCondition = "S_WAVE_NO = '"..wave_no.."'"
    nRet, data_objs = m3.QueryDataObject(strLuaDEID, "OW_Detail", strCondition, "N_ROW_NO" )
    if (nRet ~= 0) then return 2, "QueryDataObject失败!"..data_objs end
    if ( data_objs == '' ) then 
        -- 设置错误信息
        err_msg = "波次号'"..wave_no.."'的出库波次明细为空!"
        goto set_state_ret
    end
    for n = 1, #data_objs do
        detail_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
        local item = {
            item_code = lua.Get_StrAttrValue( detail_attrs.S_ITEM_CODE ),
            item_name = lua.Get_StrAttrValue( detail_attrs.S_ITEM_NAME ),
            volume = lua.Get_NumAttrValue( detail_attrs.F_VOLUME),
            weight = lua.Get_NumAttrValue( detail_attrs.F_WEIGHT),
            cell_type = lua.Get_StrAttrValue( detail_attrs.S_CELL_TYPE ),
            qty = lua.Get_NumAttrValue( detail_attrs.F_QTY),
            alloc_qty = 0,
            cntr_cell_list = {},
            ok = false                      -- true 表示这个货品已经配完货
        }
        table.insert( item_list, item )
    end

    -- 【step1】 系统自动配货算法
    -- wms_out.Distribution_Procedure 是汉和WMS的一个标准的配盘算法
    -- MDF BY WHB 20250110 area_code 改成空（原因是可以在输送线上获取容器，否则就只能是存储区匹配）
    paramter = {
        wh_code = wh_code, area_code = '', 
        exit_loc = exit_loc,
        bs_type = "Outbound_Wave",
        bs_no = wave_no,
        order_by = "S_BATCH_NO",
        station = station
    }
    nRet, strRetInfo = wms_out.Distribution_Procedure( strLuaDEID, item_list, paramter, d_cntr_list, d_cntr_detail_list, 1 )  
    if ( nRet ~= 0 ) then
        err_msg = "【step1】系统自动配货算法,详细信息见日志!"..strRetInfo
        lua.Debug( strLuaDEID, debug.getinfo(1), "【step1】系统自动配货算法出错", "wms_out.Distribution_Procedure 返回错误: "..strRetInfo )
        goto set_state_ret
    end

    lua.Debug( strLuaDEID, debug.getinfo(1), "配盘 --> ", d_cntr_list )
    lua.Debug( strLuaDEID, debug.getinfo(1), "配盘明细1 --> ", d_cntr_detail_list )    
    
    -- CG_Detail 加分配量
    nRet, strRetInfo = cg_detail_add_alloc_qty( strLuaDEID, d_cntr_detail_list )
    if ( nRet ~= 0 ) then
        err_msg = "【step1.1】CG_Detail 加分配量失败,详细信息见日志!"..strRetInfo
        lua.Debug( strLuaDEID, debug.getinfo(1), "【step1.1】CG_Detail 加分配量失败", strRetInfo )
        goto set_state_ret
    end    

    -- V2.0
    -- 配盘明细根据料格合并相同货品数量
    nRet, d_cntr_detail_list = combine_cntr_detail( d_cntr_detail_list )
    if ( nRet ~= 0 ) then
        err_msg = "【step1.2】合并配盘明细错误!"..d_cntr_detail_list
        lua.Debug( strLuaDEID, debug.getinfo(1), "【step1.2】合并配盘明细错误", d_cntr_detail_list )
        goto set_state_ret
    end
    lua.Debug( strLuaDEID, debug.getinfo(1), "配盘明细 after combine  --> ", d_cntr_detail_list ) 
 
    --【step2】 如果采用波次需要把【配盘明细】根据出库单明细进行批分
    -- 因为是采用波次出库，在生成配盘明细的 bs_type 的时候用的是 波次及波次号，在后面需要进一批批分到出库单上
    -- 如果没采用波次可以直接用 d_cntr_detail_list 生成数据

    -- step2.1 获取 出库单明细全部，如果有多个出库单把这些出库单的明细全部加在 outbound_detail_list
    nRet, outbound_detail_list = wms_out.Get_Outbound_Detail_list( strLuaDEID, oo_no_set )
    if ( nRet ~= 0 ) then
        err_msg = "【step2.1】获取所有出库单明细时出错,详细信息见日志!"
        lua.Debug( strLuaDEID, debug.getinfo(1), "【step2.1】获取所有出库单明细时出错", "wms_out.Get_Outbound_Detail_list 返回错误: "..outbound_detail_list )
        goto set_state_ret
    end
    -- step 2.2 批分出库单明细
    d_cntr_detail_list = wms_out.Split_Distribution_CNTR_Detail( strLuaDEID, wave_no, "Outbound_Wave", d_cntr_detail_list, outbound_detail_list )
    lua.Debug( strLuaDEID, debug.getinfo(1), "配盘明细2 --> ", d_cntr_detail_list ) 
    
    -- step 2.3 检查出库单中的拣料箱数量，如果大于1的要根据拣料箱进行批分（明确这些拣料箱放哪些检出的货品）
    -- HAN 20241031 新增变更
    -- 找出波次中拣料箱数量大于1的出库单，这些出库单需要对拣货箱进行批分
    strCondition = "S_WAVE_NO = '"..wave_no.."'"
    nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Order", strCondition, "S_NO" )
    if (nRet ~= 0) then 
        err_msg =  "QueryDataObject失败!" 
        goto set_state_ret
    end

    for n = 1, #data_objs do
        oo_obj_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
        pick_box_num = lua.Get_NumAttrValue( oo_obj_attrs.N_PICKING_BOX_NUM )
        pick_box_code = lua.Get_StrAttrValue( oo_obj_attrs.S_PICK_BOX_CODE )
        if (pick_box_code == '' or pick_box_num == 0 ) then
            err_msg = "出库单'"..oo_obj_attrs.S_NO.."'没有绑定拣料箱!"
            goto set_state_ret
        end
        -- 从 d_cntr_detail_list 获取该出库单号的【配盘明细】
        sub_d_cntr_detail_list = get_d_cntr_detail_by_bs_no( d_cntr_detail_list, oo_obj_attrs.S_NO )
        if ( pick_box_num == 1 ) then
            -- 把拣料箱编码加入 d_cntr_detail
            for m = 1, #sub_d_cntr_detail_list do
                sub_d_cntr_detail_list[m].pick_box_code = pick_box_code
                table.insert( new_d_cntr_detail_list, sub_d_cntr_detail_list[m] )
            end
        else
            nRet, strRetInfo = split_by_picking_box( strLuaDEID, sub_d_cntr_detail_list, pick_box_code, new_d_cntr_detail_list )

            lua.Debug( strLuaDEID, debug.getinfo(1), "拣货箱批分后-->", new_d_cntr_detail_list )

            if ( nRet ~= 0 ) then
                err_msg = "出库单'"..oo_obj_attrs.S_NO.."'在批分拣料箱时发生错误, 具体信息请见日志!"
                lua.Debug( strLuaDEID, debug.getinfo(1), "【step2.3】 批分拣料箱时出错", "split_by_picking_box 返回错误: "..strRetInfo )
                goto set_state_ret                
            end
        end
    end    

    --【step3】 创建配盘及配盘明细
    nRet, strRetInfo = wms_out.Creat_Distribution_list( strLuaDEID, d_cntr_list, new_d_cntr_detail_list  )
    if ( nRet ~= 0 ) then
        err_msg = "wms_out.Creat_Distribution_list 发生错误，具体信息请查看系统日志!"
        lua.Debug( strLuaDEID, debug.getinfo(1), "【step3】 创建配盘及配盘明细出错", "wms_out.Creat_Distribution_list 返回错误: "..strRetInfo )
        goto set_state_ret      
    end
 
    -- 设置出库波次的状态
    ::set_state_ret::
    strCondition = "S_WAVE_NO = '"..wave_no.."'"
    local strSetAttr

    if ( err_msg ~= '' ) then
        -- 5 错误
        strSetAttr = "N_B_STATE = 5, S_ERR_MSG = '"..lua.FormatSQLString(err_msg).."', N_PRE_B_STATE = "..b_state
    else
        -- 2 配货完成
        strSetAttr = "N_B_STATE = 2, S_ERR_MSG = ''"
    end
    nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Outbound_Wave", strCondition, strSetAttr )
    if ( nRet ~= 0 ) then  lua.Error( strLuaDEID, debug.getinfo(1), "更新【出库波次】信息失败!"..strRetInfo ) end 

    if ( err_msg ~= '' ) then 
        mobox.addProcSQL3("Outbound_Wave", strCondition, strSetAttr)
        mobox.stopProgram( strLuaDEID, "自动配盘失败!"..err_msg )
        return
    end
    -- 设置出库单状态 = 2 （配货完成）
    if ( err_msg == '' ) then
        strSetAttr = "N_B_STATE = 2"
        nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Outbound_Order", strCondition, strSetAttr )
        if ( nRet ~= 0 ) then  lua.Error( strLuaDEID, debug.getinfo(1), "更新【出库单】信息失败!"..strRetInfo ) end 

        -- 触发后台脚本生成出库作业
        local strCurEditClsID, strCurEditObjID
        nRet, strCurEditClsID, strCurEditObjID = mobox.getCurEditDataObjID( strLuaDEID )
        if ( nRet ~= 0 )  then lua.Error( strLuaDEID, debug.getinfo(1), "getCurEditDataObjID失败! " ) end      
        local add_wfp = {
            wfp_type = 1,
            cls = "Outbound_Wave",
            obj_id = strCurEditObjID,
            obj_name = "出库波次'"..wave_no.."'-->生成出库作业",
            trigger_event = "后台创建出库作业"
        }
        nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
        if ( nRet ~= 0 ) then 
            lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo )  
        end             
    end
end